/*
package com.gjy.rocketmq.sp;

import com.gjy.comment.AjaxResult;
import org.apache.rocketmq.client.producer.SendResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

*/
/**
 * @author 宫静雨
 * @version 1.0
 * @since 2023-01-29 11:14:02
 *//*

@RestController
@RequestMapping("/rocketmq")
public class MQController {

    @Resource
    private MQProductService mqProductService;

    @GetMapping("/send")
    public void send() {
        String user = "Hello";
        mqProductService.send(user);
    }

    @GetMapping("/sendTag")
    public AjaxResult sendTag() {
        SendResult sendResult = mqProductService.sendTagMsg("带有tag的字符消息");
        return AjaxResult.ok(sendResult);
    }

}
*/
